package com.zqj.stream1;

import com.zqj.lambda2.Employee;
import com.zqj.lambda2.EmployeeData;
import org.junit.Test;

import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * 测试Stream的终止操作
 */
public class StreamAPITest2 {
    //1.匹配与查找
    @Test
    public void test1(){
        List<Employee> employees = EmployeeData.getEmployees();
        //allMatch(Predicate p)——检查是否匹配所有元素
        //练习：是否所有员工的年龄都大于18
        boolean b = employees.stream().allMatch(e -> e.getAge() > 38);
        System.out.println(b);

        //anyMatch(Predicate p)——坚持是否至少匹配一个元素
        //练习：是否存在员工的工资大于10000
        boolean b1 = employees.stream().anyMatch(e -> e.getSalary() > 10000);
        System.out.println(b1);

        //noneMatch(Predicate p)—检查是否没有匹配的元素
        //练习：是否存在员工姓雷
        boolean b2 = employees.stream().noneMatch(e -> e.getName().startsWith("雷"));
        System.out.println(b2);

        //findFirst——返回第一个元素
        Optional<Employee> first = employees.stream().findFirst();
        System.out.println(first);

        //findAny——返回当前流中的任意元素
        Optional<Employee> any = employees.parallelStream().findAny();
        System.out.println(any);


    }

    @Test
    public void test2(){
        List<Employee> employees = EmployeeData.getEmployees();
        //count——返回流中元素的总个数
        long count = employees.stream().filter(e->e.getSalary()>8000).count();
        System.out.println(count);
        //max(Compararor c)——返回流中最大值
        //练习返回最大的工资
        Stream<Double> salaryStream = employees.stream().map(e -> e.getSalary());
        Optional<Double> maxSalary = salaryStream.max(Double::compare);
        System.out.println(maxSalary);


        //min(Comparator c)——返回流中最小值
        //返回最低工资的员工
        Optional<Employee> min = employees.stream().min((e1, e2) -> Double.compare(e2.getSalary(), e2.getSalary()));
        System.out.println(min);

        //forEach(Consumer c)内部迭代
        employees.stream().forEach(System.out::println);

        //集合的遍历操作
        employees.forEach(System.out::println);

    }
    //2-规约
    @Test
    public void test3(){
        //reduce(T identity,BinaryOperator)可以将流中的元素反复结合起来，得到一个值。返回T
        //练习1：计算1-10的自然数的和
        List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
        //0:代表初始值
        Integer sum = list.stream().reduce(0, Integer::sum);
        System.out.println(sum);

        //reduce(BinaryOperator)——可以将流中的元素反复结合起来，得到一个值。返回Optional<T>
        //练习2：计算公司所有员工的工资总和
        List<Employee> employees = EmployeeData.getEmployees();
        Stream<Double> salaryStream = employees.stream().map(Employee::getSalary);
//        Optional<Double> reduce = salaryStream.reduce(Double::sum);
        Optional<Double> reduce = salaryStream.reduce((d1, d2) -> d1 + d2);
        System.out.println(reduce);

    }
    //3-收集
    @Test
    public void test4(){
        /**
         * Collector 接口中方法的实现决定了如何对流执行收集的操作(如收集到List、Set、Map)
         * 另外，Collectors实用类提供了很多静态方法，可以方便地创建常见收集器实例，
         */
        //练习1：查找工资大于6000的员工，结果返回为一个list或Set
        List<Employee> employees = EmployeeData.getEmployees();
        List<Employee> collect = employees.stream().filter(e -> e.getSalary() > 6000).collect(Collectors.toList());
        System.out.println(collect);

        Set<Employee> set = employees.stream().filter(e -> e.getSalary() > 6000).collect(Collectors.toSet());
        set.forEach(System.out::println);

    }
}
